﻿#pragma once

#include <string>
#include <hadoop/Closable.h>

namespace HadoopPipes {

	/**
	* An object to write key/value pairs as they are emited from the reduce.
	*/
	class RecordWriter: public Closable {
	public:
		virtual void emitRecord(const std::string& key,
			const std::string& value) = 0;
	};

}